package com.jeffse.light.stream.core.function.base;

import com.jeffse.light.stream.core.data.context.SourceContext;

public interface AbstractSourceFunction<T> extends SourceFunction<T> {

    @Override
    void run(SourceContext<T> ctx) throws Exception;

    void cancel();

}
